package com.cennavi.taskSubmit;

import com.cennavi.roadNetworkFlow_XiAn.KafkaDirectFlowCal;

import azkaban.utils.Props;

/** * @author  作者 :allen
    * @date 创建时间：2017年10月26日 下午4:57:30 
    * @version 1.0 
    */

public class FlowCapacity_SubmitMain {
	/**
	 * azkaban固定写法
	 */
	private final String[] parameters;

	public FlowCapacity_SubmitMain(String name, Props props) throws Exception {
		System.out.println("************* params from azkaban *************");
		System.out.println(props.getString("parameters"));
		System.out.println("************* params from azkaban *************");
		this.parameters = props.getString("parameters").split(",");
	}

//	public FlowCapacity_SubmitMain() {
//		this.parameters = null;
//	}

	public void run() throws Exception {
		//传入给计算程序的参数：1、算法类型编号；2、输出的kafka topic（由ice接口动态生成）
		new KafkaDirectFlowCal(Integer.parseInt(this.parameters[0]), this.parameters[4].split(":")[1]).doJob();
	}
	
//	public static void main(String[] args) {
//		new KafkaDirectFlowCal(603, "azkabanroadFlowCapacityAnalysisSPEEDEVAL11111111111111").doJob();
//	}
}
